/*
package javapojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.flink.calcite.shaded.com.fasterxml.jackson.core.JsonProcessingException;
import org.apache.flink.calcite.shaded.com.fasterxml.jackson.databind.DeserializationFeature;
import org.apache.flink.calcite.shaded.com.fasterxml.jackson.databind.ObjectMapper;

import java.io.Serializable;
import java.util.List;

*/
/**
 * @author HuBiWei
 * @create 2022/6/5
 *//*

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Job implements Serializable{
    private String jobName;
    private List<Sources> sources;
    private List<Operators> operators;

    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public static class Sources implements Serializable {

    }

    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public static class Operators implements Serializable {
        private String sql;
        private List<Sinks> sinks;
    }

    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public static class Sinks implements Serializable {

    }

    public static Job apply(String json){
        try {
          return  new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES,
                    false).readValue(json,Job.class);
        } catch (JsonProcessingException e) {
            throw  new RuntimeException("json解析异常");
        }
    }
}*/
